package com.automannn.websoketmqtt.consumer.receiver.direct;

import org.springframework.amqp.rabbit.annotation.RabbitHandler;

import java.util.Map;

/**
 * @author chenkh
 * @time 2020/10/13 8:15
 */
//@Component
//@RabbitListener(queues = DirectGlobalValue.QUEUE_NAME)
public class AutomannnRabbitMQReceiverNew {

    @RabbitHandler
    public void process1(Map myMessage){
        System.out.println("消费者2受到消息: "+myMessage.toString());
    }
}
